"""
中间人(broker):
    # 2.设置borker
        # 通过加载配置文件来设置broker
        app.config_from_object('celery_tasks.config')
        config文件:broker_url='redis://127.0.0.1:6379/15'

生产者 (task): 生产请求
    sms.tasks文件:       from libs.yuntongxun.sms import CCP
                        from celery_tasks.main import app

                        @app.task
                        def celery_send_sms_code(mobile, code):
                            CCP().send_template_sms(mobile,[code,5],1)
    main:               # 3.让celery自动检测指定包的任务
                        #  autodiscover_tasks 参数是列表
                        # 列表中的元素是 tasks的路径
                        app.autodiscover_tasks(['celery_tasks.sms'])
                        队列(中间人,经纪人) (broker): 排队等待消费者消费

消费者 (worker): 消费(处理)请求
    在终端执行指令 celery -A proj worker -l info
    celery -A celery实例的脚本路径 worker -l info
    celery -A celery_task.main worker -l info
Celery -- 将这三者实现了
    # 0.为celery运行 设置Django的环境
    import os
    os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'shop_meiduo.settings')
    from celery import Celery
    # 1.创建celery实例
    # 参数1: main 设置脚本路经就可以了
    app=Celery('shop_meiduo')


"""
# 0.为celery运行 设置Django的环境
import os
os.environ.setdefault('DJANGO_SETTINGS_MODULE', 'shop_meiduo.settings')
from celery import Celery
# 1.创建celery实例
# 参数1: main 设置脚本路经就可以了
app=Celery('shop_meiduo')

# 2.设置borker
# 通过加载配置文件来设置broker
app.config_from_object('celery_tasks.config')

# 3.让celery自动检测指定包的任务
#  autodiscover_tasks 参数是列表
# 列表中的元素是 tasks的路径
app.autodiscover_tasks(['celery_tasks.sms'])

#